package som.simon.reactor;

import reactor.core.publisher.Flux;

public class FluxLimitRateMain {

    public static void main(String[] args) {

        Flux.range(1, 20)
                .log()
                .limitRate(4)   // 100 75%预取措施
                .subscribe();

    }

}
